package org.ricks.net;


import java.nio.ByteBuffer;

/**
 * @author chenwei
 * @date 2022/10/1117:38
 */
public interface Listener {

    /**
     * 连接之后
     * @param session
     */
    void onConnected(AioSession session);

    /**
     *
     * @param byteBuf the data
     * @param session
     */
    void handleReceive(ByteBuffer byteBuf, AioSession session);

    /**
     *
     * kcp异常，之后此kcp就会被关闭
     *
     * @param ex 异常
     * @param session 发生异常的kcp，null表示非kcp错误
     */
    void handleException(Throwable ex, AioSession session);

    /**
     * 关闭
     *
     * @param session
     */
    void handleClose(AioSession session);

}
